//package com.example.test.主方法运行测试;
//
//import com.google.common.util.concurrent.RateLimiter;
//
//import java.util.concurrent.ConcurrentHashMap;
//import java.util.concurrent.TimeUnit;
//
//public class GuavaRateLimiter {
//
//    public static ConcurrentHashMap<String, RateLimiter> resourceRateLimiter = new ConcurrentHashMap<String, RateLimiter>();
//
//    //初始化限流工具RateLimiter
//    static {
//        createResourceRateLimiter("order", 50);
//    }
//
//    public static void
//    createResourceRateLimiter(String resource, double qps) {
//        if (resourceRateLimiter.contains(resource)) {
//            resourceRateLimiter.get(resource).setRate(qps);
//        } else {
//            //创建限流工具，每秒发出50个令牌指令
//            RateLimiter rateLimiter = RateLimiter.create(qps);
//            resourceRateLimiter.putIfAbsent(resource, rateLimiter);
//
//        }
//
//    }
//
//    public static void main(String[] args)
//    {
//        RateLimiter limiter = RateLimiter.create(1);
//
//        for(int i = 1; i < 10; i = i + 2 ) {
//            double waitTime = limiter.acquire(i);
//            System.out.println("cutTime=" + System.currentTimeMillis() + " acq:" + i + " waitTime:" + waitTime);
//        }
//
//    }
//}
